package com.kgc.listener;

import com.kgc.constant.ActiveMqConstant;
import com.kgc.util.SendSmsUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * @Author：周申宇 <p>
 * @Date:2021/6/22 10:31
 * <p>
 * @Decription:
 */
@Component
@Slf4j
public class QueueConsumer{

    /**
     * @Auther: 周申宇
     * <p>
     * @Date: 2021/6/11
     * <p>
     * @Description:  从指定的消息队列中，获取消息，并进行业务
     *
     *          消费者通过 @JmsListener(destination = ActiveMqConstant.QUEUE_NAME_TEST)，监听生产者的队列
     *          再通过 @SendTo(ActiveMqConstant.QUEUE_NAME_RESP_TEST) 把执行的结果返回给生产者
     */
    @JmsListener(destination = "snap-user-phone",containerFactory = ActiveMqConstant.QUEUE_NAME_lISTENER_FACTORY)
    public void receiveMessageFromQueue(String phone){

        log.info("======= 3.需要发送的手机号:{} begin",phone);

        //  业务处理 例如：订单状态修改
//        SendSmsUtil.sendSms(phone,"1314");
        log.info("---测试手机号发送成功");

        log.info("======= 3.手机号发送成功:{} end",phone);
    }

}
